package com.imooc.springcloud.topic;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * Dead letter queue
 * @date 2021-04-02
 * @author zkw
 */
public interface DlqTopic {

    /** Stream-信道 */
    String INPUT = "dlq-consumer";

    String OUTPUT = "dlq-producer";
    /**
     * input:消费者
     * @return
     */
    @Input(INPUT)
    SubscribableChannel input();

    /**
     * output:生产者
     * @return
     */
    @Output(OUTPUT)
    MessageChannel output();



}
